//
#ifndef __DATA_SOURCE_H__
#define __DATA_SOURCE_H__
#include <zmq.hpp>
#include <vector>

class DataSource {
public:
    DataSource(const std::string& sourceTopicHost, const std::string& sourceTopic);
    ~DataSource();
    void mainLoop();
    std::vector<uint8_t> generateSignal();

private:
    std::string sourceTopicHost;
    std::string sourceTopic;
    zmq::context_t ctx;
    zmq::socket_t pub;
};

#endif